package com.bbcare.mqservice;

import com.bbcare.mqservice.utils.rockermq.ConsumerFactory;
import com.bbcare.mqservice.utils.rockermq.ProducerFactory;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.ApplicationArguments;
import org.springframework.boot.ApplicationRunner;
import org.springframework.stereotype.Component;

@Component
public class ApplicationRunnerStart implements ApplicationRunner {
    private static  final Logger logger = LogManager.getLogger();
    @Autowired
    private ProducerFactory producerFactory;
    @Autowired
    private ConsumerFactory consumerFactory;
    @Override
    public void run(ApplicationArguments args) throws Exception {
        /*logger.info("生产者启动");
        producerFactory.getProducer();
        logger.info("消费者启动");
        consumerFactory.getConsumer();*/
    }
}
